from celery import Celery
import os
#1.创建示列对象
app=Celery('luffy')

# 把celery和django进行组合，识别和加载django的配置文件
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'luffyapi.settings.dev')

# 在当前clery中启动django框架，对django框架进行进行初始化
import django
django.setup()

#2.加载配置
app.config_from_object("celery_tasks.config")

#3.注册任务[自动搜索并加载任务]
#参数必须是一个列表 里面的每一个任务都是任务的路径名称
#app.autodiscover_tasks(['任务1','任务2'])
app.autodiscover_tasks(["celery_tasks.sms","celery_tasks.order"])


#4.在终端下面运行celery命令启动celery
# 强烈建议切换目录到项目的根目录下启动celery!!
# celery -A celery_tasks.main worker --loglevel=info